package com.yinhai.message.client.activemq;

import com.yinhai.message.api.vo.ITMMessageVo;
import com.yinhai.message.client.activemq.util.AMQUtil;

/**
 * 消息生产
 * @author yanglq
 */
public class AMQSendThread implements Runnable {
	
	private ITMMessageVo iamqMessageVo;
	public AMQSendThread(ITMMessageVo iamqMessageVo) {
		this.iamqMessageVo = iamqMessageVo;

	}

	@Override
	public void run() {
		System.out.println("test-run");
//		AMQUtil.sendMessage(iamqMessageVo);
	}
}
